package redis_net

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

var (
	Rs  redis.Conn
	err error
)

func init() {
	Rs, err = redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil {
		fmt.Println("Connect to redis error", err)
		return
	}

}

func String_set(key, value string) {

	_, err := Rs.Do("SET", key, value)

	if err != nil {
		fmt.Println("redis set failed:", err)
	}
	return
}

func String_get(key string) string {

	value, err := redis.String(Rs.Do("GET", key))
	if err != nil {
		fmt.Println("redis get failed:", err)
	}
	return value
}

// var (
//     // 定义
//     RedisClient     *redis.Pool
//     REDIS_HOST string
//     REDIS_DB   int
// )
// func init() {
//     // 从配置文件获取redis的ip以及db
//     REDIS_HOST = beego.AppConfig.String("redis.host")
//     REDIS_DB, _ = beego.AppConfig.Int("redis.db")
//     // 建立连接池
//     RedisClient = &redis.Pool{
//         // 从配置文件获取maxidle以及maxactive，取不到则用后面的默认值
//         MaxIdle:     beego.AppConfig.DefaultInt("redis.maxidle", 1),
//         MaxActive:   beego.AppConfig.DefaultInt("redis.maxactive", 10),
//         IdleTimeout: 180 * time.Second,
//         Dial: func() (redis.Conn, error) {
//             c, err := redis.Dial("tcp", REDIS_HOST)
//             if err != nil {
//                 return nil, err
//             }
//             // 选择db
//             c.Do("SELECT", REDIS_DB)
//             return c, nil
//         },
//     }
// }
